package com.qf.chinatelcom.smsatragety.mq.stream;

import com.qianfeng.smsplatform.common.constants.RabbitMqConsants;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;


public interface LocalCacheChangeStream {

    //根据流发送消息队列
    @Input(RabbitMqConsants.TOPIC_STRATEGYEXECFILTERS_UPDATE)
    SubscribableChannel stragetyFilterChangeChannel();

    @Input(RabbitMqConsants.TOPIC_BLACKNUM_UPDATE)
    SubscribableChannel blackListChangeChannel();

    @Input(RabbitMqConsants.TOPIC_DIRTYWORDS_UPDATE)
    SubscribableChannel dirtyChangeChannel();

    @Input(RabbitMqConsants.TOPIC_LIMIT_UPDATE)
    SubscribableChannel limitChangeChannel();

}
